package com.atguigu.bigdata.spark

import org.apache.spark.{SparkConf, SparkContext}


object Spark02_Oper8 {

  def main(args: Array[String]): Unit = {
    //创建SparkConf
    //s设定spark计算框架的运行环境
    val config: SparkConf = new SparkConf().setMaster("local[*]").setAppName("wordCount")
    //创建Spark上下文环境
    val sc = new SparkContext(config)

    val listRDD = sc.makeRDD(1 to 10)
    //  从指定的数据集合中进行抽样处理，根据不同而算法进行抽样
    //    val sampleRDD = listRDD.sample(false,0.7,1)
    val sampleRDD = listRDD.sample(true, 4, 1)
    sampleRDD.collect().foreach(println)

  }
}
